package cas.ihep.spark.util;

import org.apache.spark.SparkConf;
import org.apache.spark.SparkEnv;
import org.apache.spark.serializer.Serializer;

public class JavaSparkEnv {

    private JavaSparkEnv(){
    }
    SparkConf getConf(){
        return SparkEnv.get().conf();
    }
    private static final JavaSparkEnv singleton=new JavaSparkEnv();
    public static JavaSparkEnv get(){
        return singleton;
    }

    public Serializer serializer(){
        return SparkEnv.get().serializer();
    }

}
